package com.chb.friend2;

import java.io.IOException;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;
/**
 * 上一个maperduce的输出作为这个mapper的输入
 *  用户1  用户2    fof的数量
 *   a     b         3
 * 现在我们需要按照用户1的姓名分组
 * 按照fof的数量排序，
 * 所以创建一个类User包含这两个元素
 */
public class SortMapper extends Mapper<Text, Text, User, User>{
	@Override
	protected void map(Text key, Text value, Context context) throws IOException,
			InterruptedException {
		String args[] = value.toString().split("\t");
		String other = args[0];
		int fofNum = Integer.parseInt(args[1]);
		//输出
		context.write(new User(key.toString(), fofNum), new User(other, fofNum));
	}
}
